package com.lry.basic.algorithm.flow.bucket;

public class Test {
    public static void main(String[] args) throws InterruptedException {

        Bucket bucket = new Bucket(10,2);

        for(int i=0;i<100;i++){
            System.out.println(bucket.acquire());
            Thread.sleep(100);
        }

    }
}
